package com.ruoyi.stream.framework.model;

import com.ruoyi.stream.framework.core.protocol.SKAProtocolContext;
import com.ruoyi.stream.framework.core.protocol.StreamAliveRequest;
import com.ruoyi.stream.framework.core.protocol.StreamAliveResponse;
import com.ruoyi.stream.framework.model.configBuilder.IOTaskConfigBuilder;

import java.io.InputStream;

public interface StreamServiceEndpointHandler {
    Object onRequest(StreamAliveRequest request, StreamAliveResponse response);
    boolean onReady(StreamAliveRequest request, SKAProtocolContext context, IOTaskConfigBuilder<?> config);
    InputStream start(StreamAliveRequest request, SKAProtocolContext context);
    void onError(StreamAliveRequest request,StreamAliveResponse response);
    void onRefuse(StreamAliveRequest request,StreamAliveResponse response);
}
